Skip to content

Add support for multi-threadded Queue loading #45

Conversation

campb303
Copy link
Collaborator

@campb303 campb303 commented Aug 2, 2021

No description provided.

benne238 and others added 7 commits July 12, 2021 09:38
…e starmap_async function in the multiprocessing package
…at represent the different queues) and a headers_only boolean value. Modified the docstring accordingly
…custom class from the previous comitt that allows subprocesses to spawn other subprocesses
@@ -178,15 +186,40 @@ def get_queue_counts() -> list:

return sorted_queue_info

def load_queues() -> list:
"""Return a list of Queues for each queue.
def load_queues(*queues, headers_only: bool = True) -> list:
Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Add type to queues

def load_queues(*queues, headers_only: bool = True) -> list:
"""Returns a list of queues

Example:
Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Add example.


Args:
headers_only (bool, optional): Weather or not the content of items in the queue should be loaded. Defaults to True.
*queues: List of strings that represent Queue names.
Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Add type to queues.

@campb303 campb303 merged commit c88dc30 into staging Aug 2, 2021
@campb303 campb303 deleted the feature-implement-multiparsing-when-loading-multiple-queues-and-items branch August 2, 2021 22:20
Sign in to join this conversation on GitHub.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants